package com.coderman.infosys.auth.infrast.mq.consumer;


import com.alibaba.fastjson.JSON;
import com.coderman.infosys.auth.domain.bo.msgbody.DepartmentChangeMsgBody;
import org.springframework.stereotype.Component;
import org.springframework.stereotype.Service;

/**
 * @Description:监听组织状态变化
 *
 * 一般来说对于消息监听不同的业务工程或者框架都有不同的实现，这里不再具体集成某个消息中间件
 * 而是通过统一的消息处理接口进行内部路由
 *
 * 比较好的方式是在MqConsumeHandler的实现类上绑定自定义注解，然后根据消息监听的一些消息元数据内部做路由，这样会达到一个相对解耦合的目的
 * 所以这里仅仅是演示DDD+COLA项目工程的消息消费逻辑的整体实现，你可以认为是模拟或者mock的服务，另外一方面为了
 * 保障整个演示工程可以启动而不需要太多的中间件会做的相对轻量，但是仍然不影响整个权限工程的完整性。
 *
 * @Author:shenshuai
 * @CreateTime:2022-01-02 15:27:38
 * @version v1.0
 *
 */
@Component(value = "departmentMqConsumer")
public class DepartmentMqConsumer implements MqConsumeHandler{


   @Override
   public boolean consume(String jsonMsgBody) {
      DepartmentChangeMsgBody departmentChangeMsgBody = JSON.parseObject(jsonMsgBody,DepartmentChangeMsgBody.class);


      return true;
   }


}